kafka发送自定义消息体（对象、数组）

您所在的位置：网站首页 › kafka 传输文件 › kafka发送自定义消息体（对象、数组）

kafka发送自定义消息体（对象、数组）

2024-07-16 16:14| 来源: 网络整理| 查看: 265

在前面简单搭建了Windows上的kafka环境，并使用命令行测试可以运行之后（环境请参考：http://blog.csdn.net/u014104286/article/details/75040932）我们会考虑怎么使用kafka；先试着发送一个简单的消息，发送成功之后是否需要发送自定义的消息类尼？怎么发送自定义的消息类，如果我要发送一个集合呢？下面我们来一一解决我们的问题。

准备工作：

1.需要搭建并测试成功的kafka环境，并启动zookeeper和kafka服务。

2.创建一个可用的maven项目

3.添加开发kafkaka的依赖：

[html] view plain copy org.apache.kafka kafka_2.11 0.10.2.0

准备工作完成。

1.首先我们要发送第一个消息，消息类型为String：

Producer发送消息类：

[java] view plain copy public class SimpleProducer { public static void main(String[] args) throws Exception{ //Assign topicName to string variable String topicName = "newtest001"; // create instance for properties to access producer configs Properties props = new Properties(); //Assign localhost id props.put("bootstrap.servers", "localhost:9092"); //Set acknowledgements for producer requests. props.put("acks", "all"); //If the request fails, the producer can automatically retry, props.put("retries", 0); //Specify buffer size in config props.put("batch.size", 16384); //Reduce the no of requests less than 0 props.put("linger.ms", 1); //The buffer.memory controls the total amount of memory available to the producer for buffering. props.put("buffer.memory", 33554432); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); Producer producer = new KafkaProducer(props); for(int i = 0; i

【本文地址】

kafka发送自定义消息体（对象、数组）

kafka发送自定义消息体（对象、数组）

今日新闻

推荐新闻